const Stomp = require('stomp-client');
const base = require('../config/base');
var b = new base();

var destination = b.jms.dish_jms_destination;
var client = new Stomp(b.jms.jms_ip, b.jms.jms_port, '');

exports.recommendDishJMS = function (data) {
        var count=0;
    client.connect(function (sessionId) {
        if(count==0) {
            client.publish(destination, data);
            count++;
        }

    });

}

// var rd=function recommendDish(data) {
//     var count=0;
//     client.connect(function (sessionId) {
//         // if(count==0) {
//             console.log('a****'+data);
//             client.publish(destination, data);
//             // count++;
//         // }else{
//         //     console.log('11');
//         // }
//     });
// }
//
// function dishJms(){
//     this.rd=rd;
// }
//
//
// module.exports=dishJms;
